package simple;

import util.ConnUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import org.junit.Test;
import util.ConnUtil;

import java.io.IOException;

/**
 * @author TZL
 * @date 2020/8/13
 * 生产者的类
 */
public class Publisher {
    //队列名称
    public static final String QUEUE_NAME = "HELLO";

    @Test
    public void publish() throws Exception {
        //1. 获取连接对象
        Connection conn= ConnUtil.getConn();

        //1. 获取通道对象
        Channel channel = conn.createChannel();

        //3. 通过channe声明一个队列
        //String queue(队列名称),boolean durable(队列是否持久化)，
        // boolean exclusive(队列是否排外)，boolean autoDelete（自动删除队列）
        //Map<String, Object> arguments(其他属性)
        channel.queueDeclare(QUEUE_NAME,true,false,false,null);

        //4. 通过channel发送消息到队列中
        String msg = "Hello World！你好";
        channel.basicPublish("",QUEUE_NAME,null,msg.getBytes());

        //5. 输出结果
        System.out.println(msg+"消息发送成功！！");
        channel.close();
        conn.close();


    }




}
